package com.atguigu.flink.func;

import com.alibaba.fastjson.JSON;
import com.atguigu.flink.pojo.Event;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

/**
 * @author WEIYUNHUI
 * @date 2023/6/14 15:14
 *
 * 自定义Sink ， 需要实现 SinkFunction
 */
public class MySinkFunction implements SinkFunction<Event> {

    @Override
    public void invoke(Event value, Context context) throws Exception {
        // 按照需求将数据写到对应的位置。
        System.out.println(JSON.toJSONString(value));
    }
}
